package com;

import com.dto.ProjectType;
import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;

import java.time.LocalDateTime;

/**
 * @description:
 * @author: sksun2
 * @create: 2023-08-31
 */
public class ProjectTypeCustomeSink extends RichSinkFunction<ProjectType> {

    @Override
    public void invoke(ProjectType value, Context context) throws Exception {
        System.out.println("监听到活动数据" + LocalDateTime.now() + value);
        System.out.println();
    }

}
